package com.atguigu.function;

import org.apache.flink.table.functions.TableFunction;

//自定义udtf函数，在flink中成为table函数
public class MySplit extends TableFunction<WordLen> {
    public void eval(String line){
        for (String word : line.split(" ")) {
            collect(new WordLen(word,word.length()));
        }
    }
}
